package cn.thirdplatform.service.listener;

import cn.thirdplatform.entity.dto.mns.MnsProductDTO;
import cn.wine.base.starter.mns.core.AbstractMnsLongPollingConsumer;
import com.aliyun.mns.model.Message;
import lombok.extern.slf4j.Slf4j;

/**
 * @author simon
 * @date 2019/5/10 14:33
 * @copyright:
 * @modifier
 * @motto a no talent, people who have to study hard
 */
@Slf4j
//@MnsConsumer(queueName = "queue-name")
public class MnsCustomConsumerListener extends AbstractMnsLongPollingConsumer<MnsProductDTO> {

    @Override
    public boolean process(MnsProductDTO mnsProductDTO, Message message) {
        log.info("{}", mnsProductDTO);
        return true;
    }
}
